package com.fxd.service;

public interface DealNoAckMessageService {

    /**
     * 处理水果生产者中未成功ack的消息
     */
    void dealFruitsProducerStream();

}
